package cn.com.idmy.mq.exception;


public class MqMsgSendException extends RuntimeException {
    public MqMsgSendException(String error) {
        super(error);
    }

    public MqMsgSendException(String topic, Exception e) {
        super("消息发送失败, topic :" + topic + ", e:" + e.getMessage(), e);
    }

    public MqMsgSendException(String msgId, String topic, Exception e) {
        super("消息发送失败, messageId:" + msgId + ", topic :" + topic + ", e:" + e.getMessage(), e);
    }
}
